package com.tyrone.hephaestus.consumer;

import com.tyrone.hephaestus.common.annotation.Listener;
import com.tyrone.hephaestus.common.entity.Msg;

@Listener(topic = "test")
public class ConsumerConcreteSec extends Consumer{
    @Override
    public void onMessage(Msg msg) {
        System.out.printf("#ConsumerConcreteSec:收到消息:{%s} \n",msg.toString());
    }
}
